@@ -35,7 +35,6 @@ def delete_objects(endpoint, ids):
3535 for object_id in ids :
3636 del_url = f"{ BASE_URL } { endpoint } /{ object_id } "
3737 requests .delete (del_url , headers = HEADERS )
38- time .sleep (0.1 ) # avoid rate limits
3938
4039# === Reset Steps ===
4140
@@ -51,6 +50,10 @@ def delete_all_deals():
5150 deal_ids = get_all_ids ("/crm/v3/objects/deals" )
5251 delete_objects ("/crm/v3/objects/deals" , deal_ids )
5352
53+ def delete_tasks ():
54+ tasks_ids = get_all_ids ("/crm/v3/objects/tasks" )
55+ delete_objects ("/crm/v3/objects/tasks" , tasks_ids )
56+
5457def create_company (name , domain ):
5558 data = {"properties" : {"name" : name , "domain" : domain }}
5659 response = requests .post (f"{ BASE_URL } /crm/v3/objects/companies" , headers = HEADERS , json = data ).json ()
@@ -97,10 +100,19 @@ def associate_deal_to_contact(deal_id, contact_id):
97100def reset_hubspot (quiet = True ):
98101 if not quiet :
99102 print ("🚨 Deleting existing data..." )
100-
103+
104+ if not quiet :
105+ print ("🗑️ Deleting contacts..." )
101106 delete_all_contacts ()
107+ if not quiet :
108+ print ("🗑️ Deleting companies..." )
102109 delete_all_companies ()
110+ if not quiet :
111+ print ("🗑️ Deleting deals..." )
103112 delete_all_deals ()
113+ if not quiet :
114+ print ("🗑️ Deleting tasks..." )
115+ delete_tasks ()
104116
105117 if not quiet :
106118 print ("📤 Loading initial data..." )
@@ -143,4 +155,4 @@ def reset_hubspot(quiet=True):
143155 print ("✔️ Reset complete!" )
144156
145157if __name__ == "__main__" :
146- reset_hubspot ()
158+ reset_hubspot (quiet = False )
0 commit comments