Automate Manual Work at Scale | Dataford Interview Questions

Given a repetitive manual task, how would you design an automated pipeline to handle it at scale? Implement schedule_pipeline(tasks, batch_size), where tasks maps each task ID to its prerequisite task IDs. Return deterministic execution batches, processing available tasks in lexicographic order and never exceeding batch_size; inputs are guaranteed to form a directed acyclic graph.

Constraints

0 <= number of tasks <= 100000
0 <= total prerequisite references <= 200000
1 <= batch_size <= 100000
Every prerequisite appears as a task ID
The dependency graph is acyclic
Task IDs are unique strings

Function Signature

def schedule_pipeline(tasks, batch_size):

Your question is Automate Manual Work at Scale. Start with the requirements in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.

Problem

Constraints

0 <= number of tasks <= 100000
0 <= total prerequisite references <= 200000
1 <= batch_size <= 100000
Every prerequisite appears as a task ID
The dependency graph is acyclic
Task IDs are unique strings

Function Signature

def schedule_pipeline(tasks, batch_size):

Your question is Automate Manual Work at Scale. Start with the requirements in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.